Node / meshtastic / Meshtastic-Android / files / core / network / src / commonTest / kotlin / org / meshtastic / core / network / radio / ReplayRadioTransportTest.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.network.radio

Tff7b72import T7ee787kotlinx.coroutines.test.runTest

Tff7b72import T7ee787okio.Buffer

Tff7b72import T7ee787org.meshtastic.core.repository.HandshakeConstants

Tff7b72import T7ee787org.meshtastic.core.repository.RadioTransportCallback

Tff7b72import T7ee787org.meshtastic.core.repository.TransportDisconnectReason

Tff7b72import T7ee787org.meshtastic.proto.FromRadio

Tff7b72import T7ee787org.meshtastic.proto.MeshPacket

Tff7b72import T7ee787org.meshtastic.proto.MyNodeInfo

Tff7b72import T7ee787org.meshtastic.proto.NodeInfo

Tff7b72import T7ee787org.meshtastic.proto.ToRadio

Tff7b72import T7ee787kotlin.test.Test

Tff7b72import T7ee787kotlin.test.assertEquals

Tff7b72import T7ee787kotlin.test.assertFailsWith

Tff7b72import T7ee787kotlin.test.assertFalse

Tff7b72import T7ee787kotlin.test.assertTrue

Tff7b72class T56d364ReplayRadioTransportTest Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3configFrames Tff7b72= Te6edf3listOfTb4b4b4(Te6edf3FromRadioTb4b4b4(Te6edf3my_info Tff7b72= Te6edf3MyNodeInfoTb4b4b4(Te6edf3my_node_num Tff7b72= T79c0ff1Tb4b4b4)Tb4b4b4)Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3nodeFrames Tff7b72=

Te6edf3listOfTb4b4b4(Te6edf3FromRadioTb4b4b4(Te6edf3node_info Tff7b72= Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff4T79c0ff2Tb4b4b4)Tb4b4b4)Tb4b4b4, Te6edf3FromRadioTb4b4b4(Te6edf3node_info Tff7b72= Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff4T79c0ff3Tb4b4b4)Tb4b4b4)Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3packetFrames Tff7b72= Tb4b4b4(T79c0ff1.Tb4b4b4.T79c0ff3Tb4b4b4)Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3FromRadioTb4b4b4(Te6edf3packet Tff7b72= Te6edf3MeshPacketTb4b4b4(Te6edf3id Tff7b72= Tffa657itTb4b4b4)Tb4b4b4) Tb4b4b4}

Tff7b72private Tff7b72class T56d364RecordingCallback Tb4b4b4: Te6edf3RadioTransportCallback Tb4b4b4{

Tff7b72var Te6edf3connects Tff7b72= T79c0ff0

Tff7b72val Te6edf3received Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3FromRadioTff7b72>Tb4b4b4(Tb4b4b4)

Tff7b72override Tff7b72fun Td2a8ffonConnectTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3connectsTff7b72+Tff7b72+

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffonDisconnectTb4b4b4(Te6edf3isPermanentTb4b4b4: Tffa657BooleanTb4b4b4, Te6edf3errorMessageTb4b4b4: Tffa657String?Tb4b4b4, Te6edf3reasonTb4b4b4: Te6edf3TransportDisconnectReason?Tb4b4b4) Tff7b72=

Tffa657Unit

Tff7b72override Tff7b72fun Td2a8ffhandleFromRadioTb4b4b4(Te6edf3bytesTb4b4b4: Te6edf3ByteArrayTb4b4b4) Tb4b4b4{

Te6edf3receivedTb4b4b4.Te6edf3addTb4b4b4(Te6edf3FromRadioTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3decodeTb4b4b4(Te6edf3bytesTb4b4b4)Tb4b4b4)

Tb4b4b4}

Tb4b4b4}

T8b949e/** Encodes the three sections in the `replay_server.py --export` asset format. */

Tff7b72private Tff7b72fun Td2a8ffassetTb4b4b4(

Te6edf3configTb4b4b4: Te6edf3ListTff7b72<Te6edf3FromRadioTff7b72> Tff7b72= Te6edf3configFramesTb4b4b4,

Te6edf3nodesTb4b4b4: Te6edf3ListTff7b72<Te6edf3FromRadioTff7b72> Tff7b72= Te6edf3nodeFramesTb4b4b4,

Te6edf3packetsTb4b4b4: Te6edf3ListTff7b72<Te6edf3FromRadioTff7b72> Tff7b72= Te6edf3packetFramesTb4b4b4,

Tb4b4b4)Tb4b4b4: Te6edf3ByteArray Tb4b4b4{

Tff7b72val Te6edf3buffer Tff7b72= Te6edf3BufferTb4b4b4(Tb4b4b4)

Tff7b72fun Td2a8ffwriteFramesTb4b4b4(Te6edf3framesTb4b4b4: Te6edf3ListTff7b72<Te6edf3FromRadioTff7b72>Tb4b4b4, Te6edf3withCountTb4b4b4: Tffa657BooleanTb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3withCountTb4b4b4) Te6edf3bufferTb4b4b4.Te6edf3writeIntTb4b4b4(Te6edf3framesTb4b4b4.Te6edf3sizeTb4b4b4)

Te6edf3framesTb4b4b4.Te6edf3forEach Tb4b4b4{

Tff7b72val Te6edf3bytes Tff7b72= Tffa657itTb4b4b4.Te6edf3encodeTb4b4b4(Tb4b4b4)

Te6edf3bufferTb4b4b4.Te6edf3writeIntTb4b4b4(Te6edf3bytesTb4b4b4.Te6edf3sizeTb4b4b4)

Te6edf3bufferTb4b4b4.Te6edf3writeTb4b4b4(Te6edf3bytesTb4b4b4)

Tb4b4b4}

Tb4b4b4}

Te6edf3writeFramesTb4b4b4(Te6edf3configTb4b4b4, Te6edf3withCount Tff7b72= Tff7b72trueTb4b4b4)

Te6edf3writeFramesTb4b4b4(Te6edf3nodesTb4b4b4, Te6edf3withCount Tff7b72= Tff7b72trueTb4b4b4)

Te6edf3writeFramesTb4b4b4(Te6edf3packetsTb4b4b4, Te6edf3withCount Tff7b72= Tff7b72falseTb4b4b4)

Tff7b72return Te6edf3bufferTb4b4b4.Te6edf3readByteArrayTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`start signals onConnect without emitting frames`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3callback Tff7b72= Te6edf3RecordingCallbackTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3transport Tff7b72=

Te6edf3ReplayRadioTransportTb4b4b4(Te6edf3callbackTb4b4b4, Te6edf3backgroundScopeTb4b4b4, Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3frames Tff7b72= Te6edf3assetTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3packetDelayMs Tff7b72= T79c0ff0Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff0Tb4b4b4, Te6edf3callbackTb4b4b4.Te6edf3connectsTb4b4b4, Ta5d6ff"Ta5d6ffconstruction must not publish lifecycle callbacksTa5d6ff"Tb4b4b4)

Te6edf3assertFalseTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3want_config_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)Tb4b4b4.Te6edf3encodeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3callbackTb4b4b4.Te6edf3connectsTb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3callbackTb4b4b4.Te6edf3receivedTb4b4b4.Te6edf3isEmptyTb4b4b4(Tb4b4b4)Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`config nonce is answered with config frames and the echoed nonce only`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3callback Tff7b72= Te6edf3RecordingCallbackTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3transport Tff7b72=

Te6edf3ReplayRadioTransportTb4b4b4(Te6edf3callbackTb4b4b4, Te6edf3backgroundScopeTb4b4b4, Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3frames Tff7b72= Te6edf3assetTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3packetDelayMs Tff7b72= T79c0ff0Tb4b4b4)

Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3accepted Tff7b72= Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3want_config_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)Tb4b4b4.Te6edf3encodeTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3acceptedTb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3configFrames Tff7b72+ Te6edf3FromRadioTb4b4b4(Te6edf3config_complete_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)Tb4b4b4, Te6edf3callbackTb4b4b4.Te6edf3receivedTb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`node nonce is answered with the node db then the packet stream`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3callback Tff7b72= Te6edf3RecordingCallbackTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3transport Tff7b72=

Te6edf3ReplayRadioTransportTb4b4b4(Te6edf3callbackTb4b4b4, Te6edf3backgroundScopeTb4b4b4, Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3frames Tff7b72= Te6edf3assetTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3packetDelayMs Tff7b72= T79c0ff0Tb4b4b4)

Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3want_config_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)Tb4b4b4.Te6edf3encodeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3expected Tff7b72= Te6edf3nodeFrames Tff7b72+ Te6edf3FromRadioTb4b4b4(Te6edf3config_complete_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4) Tff7b72+ Te6edf3packetFrames

Te6edf3assertEqualsTb4b4b4(Te6edf3expectedTb4b4b4, Te6edf3callbackTb4b4b4.Te6edf3receivedTb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`back to back handshake requests are replayed sequentially`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3callback Tff7b72= Te6edf3RecordingCallbackTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3transport Tff7b72=

Te6edf3ReplayRadioTransportTb4b4b4(Te6edf3callbackTb4b4b4, Te6edf3backgroundScopeTb4b4b4, Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3frames Tff7b72= Te6edf3assetTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3packetDelayMs Tff7b72= T79c0ff0Tb4b4b4)

Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3want_config_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)Tb4b4b4.Te6edf3encodeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3want_config_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)Tb4b4b4.Te6edf3encodeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3expected Tff7b72=

Te6edf3configFrames Tff7b72+

Te6edf3FromRadioTb4b4b4(Te6edf3config_complete_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4) Tff7b72+

Te6edf3nodeFrames Tff7b72+

Te6edf3FromRadioTb4b4b4(Te6edf3config_complete_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4) Tff7b72+

Te6edf3packetFrames

Te6edf3assertEqualsTb4b4b4(Te6edf3expectedTb4b4b4, Te6edf3callbackTb4b4b4.Te6edf3receivedTb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`a second node nonce does not restart the packet stream`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3callback Tff7b72= Te6edf3RecordingCallbackTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3transport Tff7b72=

Te6edf3ReplayRadioTransportTb4b4b4(Te6edf3callbackTb4b4b4, Te6edf3backgroundScopeTb4b4b4, Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3frames Tff7b72= Te6edf3assetTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3packetDelayMs Tff7b72= T79c0ff0Tb4b4b4)

Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3want_config_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)Tb4b4b4.Te6edf3encodeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3want_config_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)Tb4b4b4.Te6edf3encodeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3packetsSent Tff7b72= Te6edf3callbackTb4b4b4.Te6edf3receivedTb4b4b4.Te6edf3count Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packet Tff7b72!Tff7b72= Tff7b72null Tb4b4b4}

Te6edf3assertEqualsTb4b4b4(Te6edf3packetFramesTb4b4b4.Te6edf3sizeTb4b4b4, Te6edf3packetsSentTb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`handshake worker remains responsive while packet replay is streaming`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3callback Tff7b72= Te6edf3RecordingCallbackTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3transport Tff7b72=

Te6edf3ReplayRadioTransportTb4b4b4(Te6edf3callbackTb4b4b4, Te6edf3backgroundScopeTb4b4b4, Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3frames Tff7b72= Te6edf3assetTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3packetDelayMs Tff7b72= T79c0ff1Te6edf3_000Tb4b4b4)

Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3want_config_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)Tb4b4b4.Te6edf3encodeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3want_config_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)Tb4b4b4.Te6edf3encodeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(

Te6edf3callbackTb4b4b4.Te6edf3receivedTb4b4b4.Te6edf3any Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3config_complete_id Tff7b72=Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCE Tb4b4b4}Tb4b4b4,

Ta5d6ff"Ta5d6ffa repeated config handshake must not wait for the long packet replay to finishTa5d6ff"Tb4b4b4,

Tb4b4b4)

Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`non-handshake traffic is ignored`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3callback Tff7b72= Te6edf3RecordingCallbackTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3transport Tff7b72=

Te6edf3ReplayRadioTransportTb4b4b4(Te6edf3callbackTb4b4b4, Te6edf3backgroundScopeTb4b4b4, Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3frames Tff7b72= Te6edf3assetTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3packetDelayMs Tff7b72= T79c0ff0Tb4b4b4)

Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3accepted Tff7b72= Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3packet Tff7b72= Te6edf3MeshPacketTb4b4b4(Te6edf3id Tff7b72= T79c0ff9T79c0ff9Tb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3encodeTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3acceptedTb4b4b4, Ta5d6ff"Ta5d6ffa live replay transport accepts ordinary traffic before intentionally discarding itTa5d6ff"Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3callbackTb4b4b4.Te6edf3receivedTb4b4b4.Te6edf3isEmptyTb4b4b4(Tb4b4b4)Tb4b4b4)

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`close cancels replay work and rejects later handshakes`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3callback Tff7b72= Te6edf3RecordingCallbackTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3transport Tff7b72=

Te6edf3ReplayRadioTransportTb4b4b4(Te6edf3callbackTb4b4b4, Te6edf3backgroundScopeTb4b4b4, Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3frames Tff7b72= Te6edf3assetTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3packetDelayMs Tff7b72= T79c0ff1Te6edf3_000Tb4b4b4)

Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3want_config_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)Tb4b4b4.Te6edf3encodeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3receivedBeforeClose Tff7b72= Te6edf3callbackTb4b4b4.Te6edf3receivedTb4b4b4.Te6edf3toListTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(

Te6edf3receivedBeforeCloseTb4b4b4.Te6edf3isNotEmptyTb4b4b4(Tb4b4b4)Tb4b4b4,

Ta5d6ff"Ta5d6ffthe node section must replay before close so the cancellation assertion is meaningfulTa5d6ff"Tb4b4b4,

Tb4b4b4)

Te6edf3transportTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)

Te6edf3testSchedulerTb4b4b4.Te6edf3advanceTimeByTb4b4b4(T79c0ff5Te6edf3_000Tb4b4b4)

Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(Te6edf3receivedBeforeCloseTb4b4b4, Te6edf3callbackTb4b4b4.Te6edf3receivedTb4b4b4, Ta5d6ff"Ta5d6ffclose must cancel the in-flight packet streamTa5d6ff"Tb4b4b4)

Te6edf3assertFalseTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3want_config_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)Tb4b4b4.Te6edf3encodeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3callbackTb4b4b4.Te6edf3connectsTb4b4b4, Ta5d6ff"Ta5d6ffa closed replay transport must not reconnectTa5d6ff"Tb4b4b4)

Tb4b4b4}

T8b949e// ── Malformed-asset handling: the parser must fail fast with a clear error, never underflow or over-allocate. ──

T8b949e/** Builds a raw asset body so we can craft deliberately-corrupt inputs the [asset] helper cannot. */

Tff7b72private Tff7b72fun Td2a8ffrawAssetTb4b4b4(Te6edf3blockTb4b4b4: Te6edf3BufferTb4b4b4.Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4)Tb4b4b4: Te6edf3ByteArray Tff7b72= Te6edf3BufferTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3applyTb4b4b4(Te6edf3blockTb4b4b4)Tb4b4b4.Te6edf3readByteArrayTb4b4b4(Tb4b4b4)

Tf0883e@Test

Tff7b72fun Td2a8ff`truncated section count is rejected`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

T8b949e// Only two bytes — not enough for the leading u32 config count.

Te6edf3assertFailsWithTff7b72<Te6edf3IllegalArgumentExceptionTff7b72> Tb4b4b4{

Te6edf3ReplayRadioTransportTb4b4b4(Te6edf3RecordingCallbackTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3backgroundScopeTb4b4b4, Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3frames Tff7b72= Te6edf3byteArrayOfTb4b4b4(T79c0ff0Te6edf3x00Tb4b4b4, T79c0ff0Te6edf3x01Tb4b4b4)Tb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`frame length exceeding remaining bytes is rejected`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3frames Tff7b72= Te6edf3rawAsset Tb4b4b4{

Te6edf3writeIntTb4b4b4(T79c0ff1Tb4b4b4) T8b949e// config: 1 frame…

Te6edf3writeIntTb4b4b4(T79c0ff9Te6edf3_999Tb4b4b4) T8b949e// …declaring 9999 bytes…

Te6edf3writeTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff1Tb4b4b4, T79c0ff2Tb4b4b4, T79c0ff3Tb4b4b4)Tb4b4b4) T8b949e// …but only 3 follow.

Tb4b4b4}

Te6edf3assertFailsWithTff7b72<Te6edf3IllegalArgumentExceptionTff7b72> Tb4b4b4{

Te6edf3ReplayRadioTransportTb4b4b4(Te6edf3RecordingCallbackTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3backgroundScopeTb4b4b4, Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3frames Tff7b72= Te6edf3framesTb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`counted section with fewer frames than declared is rejected`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3frames Tff7b72= Te6edf3rawAsset Tb4b4b4{

Te6edf3writeIntTb4b4b4(T79c0ff3Tb4b4b4) T8b949e// config: claims 3 frames…

Te6edf3writeIntTb4b4b4(T79c0ff2Tb4b4b4)

Te6edf3writeTb4b4b4(Te6edf3byteArrayOfTb4b4b4(T79c0ff1Tb4b4b4, T79c0ff2Tb4b4b4)Tb4b4b4) T8b949e// …but provides only 1, then EOF.

Tb4b4b4}

Te6edf3assertFailsWithTff7b72<Te6edf3IllegalArgumentExceptionTff7b72> Tb4b4b4{

Te6edf3ReplayRadioTransportTb4b4b4(Te6edf3RecordingCallbackTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3backgroundScopeTb4b4b4, Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3frames Tff7b72= Te6edf3framesTb4b4b4)

Tb4b4b4}

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ff`empty config and node sections with no packets are valid`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3callback Tff7b72= Te6edf3RecordingCallbackTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3frames Tff7b72= Te6edf3rawAsset Tb4b4b4{

Te6edf3writeIntTb4b4b4(T79c0ff0Tb4b4b4) T8b949e// 0 config frames

Te6edf3writeIntTb4b4b4(T79c0ff0Tb4b4b4) T8b949e// 0 node frames

T8b949e// no packet bytes

Tb4b4b4}

Tff7b72val Te6edf3transport Tff7b72=

Te6edf3ReplayRadioTransportTb4b4b4(Te6edf3callbackTb4b4b4, Te6edf3backgroundScopeTb4b4b4, Te6edf3address Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4, Te6edf3frames Tff7b72= Te6edf3framesTb4b4b4, Te6edf3packetDelayMs Tff7b72= T79c0ff0Tb4b4b4)

Te6edf3transportTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)

Te6edf3assertTrueTb4b4b4(Te6edf3transportTb4b4b4.Te6edf3handleSendToRadioTb4b4b4(Te6edf3ToRadioTb4b4b4(Te6edf3want_config_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)Tb4b4b4.Te6edf3encodeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4)

Te6edf3testSchedulerTb4b4b4.Te6edf3runCurrentTb4b4b4(Tb4b4b4)

T8b949e// Only the injected config_complete — no nodes, no packets — proves zero-length sections parse cleanly.

Te6edf3assertEqualsTb4b4b4(Te6edf3listOfTb4b4b4(Te6edf3FromRadioTb4b4b4(Te6edf3config_complete_id Tff7b72= Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)Tb4b4b4)Tb4b4b4, Te6edf3callbackTb4b4b4.Te6edf3receivedTb4b4b4)

Tb4b4b4}

Tb4b4b4}